package com.ibm.cps.processors;

import java.util.Collection;

import com.ibm.cps.message.ParsedDataMessage;
import com.ibm.interfaces.ITimeSeriesSchema;
import com.ibm.util.exception.CPSException;

public abstract class BasicProcessor extends AbstractProcessor {

	public BasicProcessor(String tenantId, String processorId, String source, ITimeSeriesSchema parentSchema) throws CPSException {
		super(tenantId, processorId, source);
	}

	abstract public Collection<ParsedDataMessage> execute(
			ParsedDataMessage message) throws CPSException;
}
